package com.sf.iisp.kafka.adapter;

import com.sf.kafka.api.IResource;

import java.util.List;

public interface IKafkaProducerPoolDelegate extends IResource {

    /**
     * 发送kafka 消息（字符串）
     *
     * @param msg 消息内容
     */
    public void sendString(String msg);

    /**
     * 发送kafka消息（字节数组）
     *
     * @param msg
     */
    public void sendByte(byte[] msg);

    /**
     * 批量发送kafka消息（字符串）
     *
     * @param messages 消息列表
     */
    public void sendBatchString(List<String> messages);

    /**
     * 批量发送kafka消息（字节数组）
     *
     * @param messages 消息列表
     */
    public void sendBatchBytes(List<byte[]> messages);
}
